from bdp.pyjob.BaseSparkJob import BaseSparkJob
from bdp.pyjob.FieldDescriptor import FieldDescriptor
from bdp.pyjob.JobContext import JobContext
from bdp.pyjob.JobInputStream import JobInputStream
from bdp.pyjob.JobOutputStream import JobOutputStream
from bdp.pyjob.PropertyDescriptor import PropertyDescriptor


class tmp_pyspark(BaseSparkJob):

${rawScript}